package com.ftg.learn.entity;

import lombok.Data;

import java.util.List;
import java.util.Map;

@Data
public class CanalMessageEntity {
    private String database;
    private String table;
    private String type;
    private List<Map<String, String >> data;
    private List<Map<String, String >> old;
    private Boolean isDdl;
    private String sql;
    private List<String> pkNames;
    private Map<String, String> mysqlType;
    private Map<String, Integer> sqlType;
    private Long es;  // event timestamp (ms)
    private Long ts;  // process timestamp (ms)
    private String gtid;
    private Integer id;
}
